package com.wu.concurencys.com.wu.concurencys.com.wu.concurencys.six;

import lombok.extern.slf4j.Slf4j;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

@Slf4j
public class CopyOnWriteArrayListExample {

    // 请求线程总数
    public static int clientTotal = 5000;
    //并发执行的线程数目
    public static int threadTotal = 200;
    private  static List<Integer> list = new CopyOnWriteArrayList<>();

    public static void main(String[] args) throws InterruptedException {
        ExecutorService executorService = Executors.newCachedThreadPool();
        final Semaphore semaphore = new Semaphore(threadTotal);
        final CountDownLatch countDownLatch = new CountDownLatch(clientTotal);
        for (int i=0;i<clientTotal;i++)
        {
            final  int count = 1;
            executorService.execute(() ->{
               try {
                   semaphore.acquire();
                   update(count);
                   semaphore.release();
               }catch (Exception e)
               {
                log.info("异常---",e);
               }
               countDownLatch.countDown();
            });
        }
        countDownLatch.await();
        executorService.shutdown();
        log.info("seize:{}",list.size());
    }
    public static  void update(int i)
    {
        list.add(i);
    }



}
